package com.xinqi.common.rocketmq.annotation;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * @author linkai
 * @date 2023/11/18
 */
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MqConsumer {

    /**
     * 消费者组，不配置，则取class类名
     */
    String groupName() default "";

    /**
     * 消费者订阅的主题
     */
    String topic();


    /**
     * 标签
     */
    String tag() default "";

    /**
     * 消费线程数
     */
    int consumptionThreadCount() default 5;

}
